/*******************************************************
> Copyright (C) 2024 ==iot== All rights reserved.
> File Name: 1.c
> Author: wyf
> Created Time: 2024年08月08日 星期四 16时00分55秒
***************************************************/


#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <dirent.h> //目录名获取配合DIR
#include <assert.h>
#include <sys/stat.h>
#include <sys/types.h>
#include <unistd.h>
#include <fcntl.h> //文件控制操作
#include <sys/types.h> //获取pid等
#include <sys/wait.h> //等待子进程结束
#include <time.h> //时间获取
#include <sys/ipc.h> //进程通信
#include <sys/msg.h> //消息队列
#include <sys/shm.h> //共享内存
#include <signal.h> //信号处理
#include <pthread.h> //线程
#include <semaphore.h>

typedef struct content
{
	sem_t read;
	sem_t write;
	int data;
}CT;

void *fun1(void *arg)
{
	CT *p =(CT*)arg;
	while(1)
	{
		sem_wait(&p->write);
		p->data = p->data + 1;
		sem_post(&p->read);
		sleep(1);
	}
}

void *fun2(void *arg)
{
	CT *p =(CT*)arg;
	while(1)
	{
		sem_wait(&p->read);
		printf("data = %d\n",p->data);
		sem_post(&p->write);
		
	}


}

int main()
{
	//要传的结构体
	CT k;
	k.data = 0;	

	pthread_t tid1 = 0,tid2 = 0;
	int ret = 0;

	sem_init(&k.write,0,1);
	sem_init(&k.read,0,0);

	ret = pthread_create(&tid1,NULL,fun1,&k);
	if(ret != 0)
	{
		perror("pthread_create");
		exit(-1);
	}

	ret = pthread_create(&tid2,NULL,fun2,&k);
	if(ret != 0)
	{
		perror("pthread_create");
		exit(-1);
	}
	
	pthread_join(tid1,NULL);
	pthread_join(tid2,NULL);

	sem_destroy(&k.read);
	sem_destroy(&k.write);


	return 0;

}


